package com.zenika.amqp;

import org.apache.log4j.Logger;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;

public class AMQPMessageDriven implements MessageListener {

	private static Logger logger = Logger.getLogger(AMQPMessageDriven.class);

	public void onMessage(Message message) {
		logger.info(">>> RECEIVING : " + message.getMessageProperties().getReceivedRoutingKey() + " " + message);
	}
}
